Skip to content

Applies to

net10.0, net10.0-browserwasm1.0, net10.0-desktop1.0, net9.0, net9.0-browserwasm1.0, net9.0-desktop1.0, net8.0, net8.0-ios17.5, net8.0-maccatalyst17.5, net8.0-macos14.2, net8.0-macos14.5, net8.0-tvos17.2, netstandard2.1, net462, net481

protected override ValueTask OnNextAsyncCore(ImmutableArray<IObserverAsync<T>> observers, T value, CancellationToken cancellationToken)

View source

Summary: Forwards the specified value to all observers asynchronously.

Parameters

NameTypeDescription
observersImmutableArray>A read-only list of observers that will receive the value. Cannot be null.
valueTThe value to be sent to each observer.
cancellationTokenCancellationTokenA cancellation token that can be used to cancel the forwarding operation.

Returns: ValueTask -- A ValueTask that represents the asynchronous forwarding operation.

Remarks

Observers are notified concurrently. If cancellation is requested, the operation may terminate before all observers are notified.